package org.example.common.configs.queue.disruptor;

import org.springframework.stereotype.Component;

import java.util.concurrent.atomic.AtomicInteger;

/**
 * @author weigang
 * @create 2022-07-11 14:29
 */
@Component
public class DisruptorStat {
    /**
     *  当前正在执行或者待执行的事件数量
     */
    public AtomicInteger currentEventCounter = new AtomicInteger(0);
}
